package com.ydl.learning.flink.demo.pipeline.java;

import org.apache.flink.streaming.api.datastream.DataStream;

/**
 * 完成流的输出
 */
public interface Sink<T> extends BaseProcedure {

  /**
   *
   */
  void setSource(DataStream<T> source);

  /**
   *
   */
  void sink();

}